package com.ziyucoding.springboot.labs.lab3.sca.rocketmqdemo.consumerdemo.listener;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * Input Binding
 *
 * @author ziyucoding
 * @date 2022-10-24
 **/
public interface MySink {

    String DEMO1_INPUT = "demo1-input";

    @Input(DEMO1_INPUT)
    SubscribableChannel demo1Input();
}
